pyspark real time scenarios